//package com.china.produce.controller;
//
//import com.alibaba.fastjson.JSON;
//import com.china.produce.pojo.order.OrderDTO;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.beans.factory.annotation.Qualifier;
//import org.springframework.kafka.core.KafkaTemplate;
//import org.springframework.web.bind.annotation.PostMapping;
//import org.springframework.web.bind.annotation.RestController;
//
///**
// * @ClassName
// * @Author niujie
// * @Version
// * @Description
// * @CreateTime 2023/12/3
// */
//@Slf4j
//@RestController
//public class OrderController {
//
//    @Autowired
//    @Qualifier("kaTemplate")
//    private KafkaTemplate<String, String> kafkaTemplate;
//
//    @PostMapping("/send")
//    public void send() {
//
//        for (long i = 0; i < 10; i++) {
//            OrderDTO order = new OrderDTO();
//            order.setOrderName("订单" + i);
//            order.setId(i);
//
//            kafkaTemplate.send("test.kafka.ack3", JSON.toJSONString(order));
//        }
//
//        System.out.println("发送消息 !");
//    }
//}
